type google.golang.org/grpc.csAttempt
37 uses
google.golang.org/grpc (current package)
rpc_util.go#L182: after(*callInfo, *csAttempt)
rpc_util.go#L191: func (EmptyCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L225: func (o HeaderCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L247: func (o TrailerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L269: func (o PeerCallOption) after(_ *callInfo, attempt *csAttempt) {
rpc_util.go#L308: func (o FailFastCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L343: func (o OnFinishCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L367: func (o MaxRecvMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L397: func (o AuthorityOverrideCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L421: func (o MaxSendMsgSizeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L444: func (o PerRPCCredsCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L472: func (o CompressorCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L509: func (o ContentSubtypeCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L548: func (o ForceCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L588: func (o ForceCodecV2CallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L613: func (o CustomCodecCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L641: func (o MaxRetryRPCBufferSizeCallOption) after(*callInfo, *csAttempt) {}
stream.go#L355: op := func(a *csAttempt) error {
stream.go#L410: func (cs *clientStream) newAttemptLocked(isTransparent bool) (*csAttempt, error) {
stream.go#L459: return &csAttempt{
stream.go#L469: func (a *csAttempt) getTransport() error {
stream.go#L493: func (a *csAttempt) newStream() error {
stream.go#L579: attempt *csAttempt
stream.go#L591: op func(a *csAttempt) error
stream.go#L597: type csAttempt struct {
stream.go#L647: func (a *csAttempt) shouldRetry(err error) (bool, error) {
stream.go#L744: func (cs *clientStream) retryLocked(attempt *csAttempt, lastErr error) error {
stream.go#L777: func (cs *clientStream) withRetry(op func(a *csAttempt) error, onSuccess func()) error {
stream.go#L825: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L877: func (cs *clientStream) replayBufferLocked(attempt *csAttempt) error {
stream.go#L886: func (cs *clientStream) bufferForRetryLocked(sz int, op func(a *csAttempt) error, cleanup func()) {
stream.go#L943: op := func(a *csAttempt) error {
stream.go#L981: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L1006: op := func(a *csAttempt) error {
stream.go#L1093: func (a *csAttempt) sendMsg(m any, hdr []byte, payld mem.BufferSlice, dataLength, payloadLength int) error {
stream.go#L1119: func (a *csAttempt) recvMsg(m any, payInfo *payloadInfo) (err error) {
stream.go#L1183: func (a *csAttempt) finish(err error) {